package org.pb.basic.util;

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * 建立消息队列连接通道的工具类
 * @author pb
 */
public class ConnectionUtils {

    public static Connection getConnection() throws Exception {
        // 创建一个连接工厂类对象
        ConnectionFactory factory = new ConnectionFactory();
        // 设置rabbitMq连接对象通道的参数:
        // 1. 服务地址【ip地址】：
        factory.setHost("127.0.0.1");
        // 2. 设置端口号: RabbitMQ的服务端口号为15672，这里的端口号设置为自定义端口号5672
        factory.setPort(5672);
        // 3. 设置登录账号和密码、还有虚拟主机地址：
        factory.setVirtualHost("/");
        factory.setUsername("pb");
        factory.setPassword("pb112");

        // 参数设置完成，返回连接对象
        return factory.newConnection();
    }

}
